package com.mk.remotelog;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 远程日志接受服务
 * 仅支持单机
 */
public class LogServer {
    public static void main(String[] args) {
        try(ServerSocket serverSocket = new ServerSocket(8080)){
            while (true){
                // 若插件重启 则需要重写建连接 这里为了不重启服务 写循环
                Socket socket = serverSocket.accept(); //阻塞方法
                BufferedReader socketIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                while(true){
                    try{
                        // 阻塞接受日志
                        System.out.println(socketIn.readLine());
                    }catch (Exception e){
                        // 一般到这都是连接断了 跳出循环重新阻塞建连接即可
                        break;
                    }
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }

    }
}
